//////////////////////////////////////////////////////////////////////////////////
//	 Copyright 2011 by Yosef Grabivker, ryuho@homenetworksoft.com
//
//   Licensed under the Apache License, Version 2.0 (the "License");
//   you may not use this file except in compliance with the License.
//   You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
//   Unless required by applicable law or agreed to in writing, software
//   distributed under the License is distributed on an "AS IS" BASIS,
//   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
//   See the License for the specific language governing permissions and
//   limitations under the License.
//////////////////////////////////////////////////////////////////////////////////

#ifndef _COMMANDQUEUE_YG_H_
#define _COMMANDQUEUE_YG_H_

#include "def.h"
#include <wx/thread.h>

class CCommandQueue
{
public:
							CCommandQueue();
							~CCommandQueue();
	
	void					AddRequest(const COMMANDREQUEST& cmd, bool bHead=false);
	void					AddResponce(const COMMANDRESPONSE& cmd);
	
	bool					GetRequest(COMMANDREQUEST& cmd);
	bool					GetResponce(COMMANDRESPONSE& cmd);

	size_t					GetReqQueueSize() const { return m_qIn.size(); }
	
private:
	typedef std::queue<COMMANDRESPONSE> RESPONCEQUEUE;
	typedef std::queue<COMMANDREQUEST> 	REQUESTQUEUE;
	
	wxCriticalSection		m_csOutGuard;
	wxCriticalSection		m_csInGuard;
	
	RESPONCEQUEUE			m_qOut;
	REQUESTQUEUE			m_qIn;
};

#endif /*COMMANDQUEUE_H_*/
